package com.openlogic.datasource.api.event;

import org.noear.solon.cloud.CloudClient;
import org.noear.solon.cloud.model.Event;

import com.alibaba.fastjson2.JSONObject;

/**
* @ClassName: DataCacheEvent
* @Description: 缓存元数据事件
* @author weiyongpeng
* @date 2024年11月18日 上午9:04:26
 */
public class DataCacheEvent{

	
	/**
	* 描述：缓存数据源事件
	* @Title: publishCacheEvent
	* @param dataCacheEventModel
	* @author weiyongpeng
	 * @return 
	* @date  2024年11月10日 下午6:02:50
	 */
	public boolean publishCacheEvent(DataCacheEventModel dataCacheEventModel) {
		// 这里使用的是eventplus分布式事件扩展包，需要配合Solon Cloud Event插件使用，这里使用rabbitmq作为事件处理器组件
		Event event = new Event("data.cache.event",JSONObject.toJSONString(dataCacheEventModel)).group("cache");
		return CloudClient.event().publish(event);
	}
}
